package create_thread;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

/**
 * 目标：掌握线程的创建方式三：实现Callable接口
 */
public class ThreadTest3 {
    public static void main(String[] args) throws Exception {
        // 3.创建一个Callable的对象
        Callable<String> call = new MyCallable(100);
        // 4.把Callable类型对象封装成FutureTask对象(线程任务对象)
        /**
         * 未来任务对象的作用？
         * ①：是一个任务对象，实现了Runnable对象
         * ②：可以在线程执行完毕之后,用未来任务对象调用get方法获取线程执行完毕后的结果
         */
        FutureTask<String> f1 = new FutureTask<>(call);
        // 5.把未来任务对象交给一个Thread对象
        new Thread(f1).start();

        Callable<String> call2 = new MyCallable(200);
        FutureTask<String> f2 = new FutureTask<>(call2);
        new Thread(f2).start();

        // 6.获取线程执行完毕后返回的结果
        /**
         * 注意：如果执行到这儿，假如上面线程还没有执行完毕,
         *      这里的代码会暂停,等待上面线程执行完毕后才会获取结果
         */
        String rs = f1.get(); //返回的是call方法返回的结果
        System.out.println(rs);

        String rs2 = f2.get(); //返回的是call方法返回的结果
        System.out.println(rs2);
    }
}
